package com.eshipenet.shipnet.edgeboxextbuilder
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer

object EdgeBoxExtActionSinkProvider {

  lazy val kafkaSink =
    new FlinkKafkaProducer[EdgeBoxExtAction]("demo.eshipe.net:9092",
                                             "EdgeBoxExt",
                                             new EdgeBoxExtActionKafkaSerializer("EdgeBoxExt"))

}
